import mysql from 'mysql';
const {MYSQL_CONF} = require("./dbconfig")
let con = mysql.createPool(MYSQL_CONF)


const env=process.env.NODE_ENV

console.log("数据库连接成功");

function exec(sql:string,params:Array<any>=[],cb:Function|null=null){
  return new Promise<any>((resolve,reject)=>{
    con.getConnection(function(err:any,con:any){
      if(err){
        if(cb){
          cb(err)
        }
        reject(err)
      }else{        
        con.query(sql,params,(err:any,data:any)=>{
          if(err){
            if(cb){
              cb(err)
            }
            reject(err)
          }else{
            if(cb){
              cb(err)
            }
            con.release()
            resolve(data)
          }
        })
      }
    })
  }).catch(err=>{    
    if(env==="dev"){
      console.log(err);
    }else{
      return 
    }
  })
}

export default exec

